64550d09651d46d19fc7567aec5431005eb63bdd,providers/tcp/src/java/org/mule/providers/tcp/TcpMessageReceiver.java,TcpMessageReceiver,run,#,122

Before Change


                try {
                    socket = serverSocket.accept();
                    TcpConnector connector = (TcpConnector) this.connector;
                    socket.setReceiveBufferSize(connector.getBufferSize());
                    socket.setSendBufferSize(connector.getBufferSize());
                    socket.setSoTimeout(connector.getReceiveTimeout());
                    logger.trace("Server socket Accepted on: " + serverSocket.getLocalPort());
                } catch (java.io.InterruptedIOException iie) {
                    logger.debug("Interupted IO doing serverSocket.accept: " + iie.getMessage());

After Change


                    socket = serverSocket.accept();
                    TcpConnector connector = (TcpConnector) this.connector;
                    if (connector.getBufferSize() != UMOConnector.INT_VALUE_NOT_SET && socket.getReceiveBufferSize() != connector.getBufferSize()) {
                        socket.setReceiveBufferSize(connector.getBufferSize());
                    }
                    if (connector.getBufferSize() != UMOConnector.INT_VALUE_NOT_SET && socket.getSendBufferSize() != connector.getBufferSize()) {
                        socket.setSendBufferSize(connector.getBufferSize());
                    }
                    if (connector.getReceiveTimeout() != UMOConnector.INT_VALUE_NOT_SET && socket.getSoTimeout() != connector.getReceiveTimeout()) {
                        socket.setSoTimeout(connector.getReceiveTimeout());
                    }
                    socket.setTcpNoDelay(true);
                    if (logger.isTraceEnabled()) logger.trace("Server socket Accepted on: " + serverSocket.getLocalPort());